package t20240516_lineage;

public class TestReg {

    public static final String REG = "[\n]+";


    public static void main(String[] args) {

        String sql = "\n\n\n-- create table o_scdn_vod_ali_cdn_realtime_log (\n" +
                "--     `stime` string,\n" +
                "--     `domain`  string,\n" +
                "--     `method`    string,\n" +
                "--     `scheme`  string,\n" +
                "--      `uri`              string,  \n\n" +
                "--      `uri_param`        string,  \n" +
                "--      `client_ip`        string,  \n" +
                "--      `remote_ip`        string,  \n" +
                "--      `remote_port`      int,   \n" +
                "--      `request_size`     bigint,   \n" +
                "--      `request_time`     double, \n" +
                "--      `response_size`    bigint,   \n" +
                "--      `return_code`      int,   \n" +
                "--     rowtime as to_timestamp(`stime`),\n" +
                "--     proctime as proctime(),\n" +
                "--     watermark for rowtime as rowtime - interval '60' second\n" +
                "-- ) with (\n" +
                "--     'properties.bootstrap.servers' = 'bdyun-suzhou-tw04a0264.su.baidu.internal:6667,bdyun-suzhou-tw04a0265.su.baidu.internal:6667,bdyun-suzhou-tw04d0849.su.baidu.internal:6667',\n" +
                "--     'connector' = 'kafka',\n" +
                "--     'format' = 'avro-event',\n" +
                "--     'properties.group.id' = 'flink-swallow-o_scdn_vod_ali_cdn_realtime_log_statv3-swallow',\n" +
                "--     'topic' = 'o_scdn_vod_ali_cdn_realtime_log',\n" +
                "--     'properties.security.protocol' = 'SASL_PLAINTEXT',\n" +
                "--     'scan.startup.mode' = 'latest-offset',\n" +
                "--     'properties.sasl.kerberos.service.name' = 'kafka'\n" +
                "-- );";

        String s = sql.replaceAll(REG, "\n");
        System.out.println(s);


    }
}
